package nats

import (
	"charging_pile/util/protocol/mq"
	"encoding/json"
)

func TopicHandler(nc *natsClient, b []byte) {
	mqMsg := mq.Msg{}
	err := json.Unmarshal(b, &mqMsg)
	if err != nil {
		return
	}
	nc.SvcCtx.Netty.HandleMqMsg(mqMsg)
}
